package com.ybliang.plat.common.mq.kafka.producer.configuration.properties;

import java.util.LinkedHashMap;

//@ConfigurationProperties(prefix = KafkaMultiProducerProperties.PREFIX)
public class KafkaMultiProducerProperties {

    public static final String PREFIX = "plat.kafka";

    private LinkedHashMap<String, KafkaProducerProperties> producers;

    public LinkedHashMap<String, KafkaProducerProperties> getProducers() {
        return producers;
    }

    public void setProducers(LinkedHashMap<String, KafkaProducerProperties> producers) {
        this.producers = producers;
    }

    public static class KafkaProducerProperties {

        private String bootstartServers;
        private int acks;
        private int retries;
        private int batchSize;
        private int lingerMs;
        private String keySerializer;
        private String valueSerializer;

        public String getBootstartServers() {
            return bootstartServers;
        }

        public void setBootstartServers(String bootstartServers) {
            this.bootstartServers = bootstartServers;
        }

        public int getAcks() {
            return acks;
        }

        public void setAcks(int acks) {
            this.acks = acks;
        }

        public int getRetries() {
            return retries;
        }

        public void setRetries(int retries) {
            this.retries = retries;
        }

        public int getBatchSize() {
            return batchSize;
        }

        public void setBatchSize(int batchSize) {
            this.batchSize = batchSize;
        }

        public int getLingerMs() {
            return lingerMs;
        }

        public void setLingerMs(int lingerMs) {
            this.lingerMs = lingerMs;
        }

        public String getKeySerializer() {
            return keySerializer;
        }

        public void setKeySerializer(String keySerializer) {
            this.keySerializer = keySerializer;
        }

        public String getValueSerializer() {
            return valueSerializer;
        }

        public void setValueSerializer(String valueSerializer) {
            this.valueSerializer = valueSerializer;
        }
    }

}
